package com.flute.haflute.agent.topo;

import org.apache.mina.core.session.IoSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.flute.haflute.net.messaging.Message;

/**
 * 默认的集群消息处理器，当没有绑定到特定处理器时，系统将
 */
public class DefaultClusterStateListener implements ClusterMessageListener {

	private static Logger logger = LoggerFactory
			.getLogger(DefaultClusterStateListener.class);

	/*
	 * @see
	 * com.flute.haflute.agency.ClusterStateListener#handleMessage(com.flute
	 * .haflute.net.messaging.Message, org.apache.mina.core.session.IoSession)
	 */
	@Override
	public void asyncHandle(Message message, IoSession session) {
		logger.info("UNKOWN message received:{}, from host:{}",
				message.getMessageType(), session.getRemoteAddress());
	}

}
